package com.boyi.center.task;

import com.boyi.shared.kafka.KafkaResult;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


/**
 * @author tingwen
 */
public interface KafkaTask {
    Logger logger = LoggerFactory.getLogger(KafkaTask.class);

    void taskPublic(ProducerRecord<String, KafkaResult<Object>> record);

    void handleSuccess(Object result);

    void handleFailure(ProducerRecord<String, KafkaResult<Object>> record);

}
